package com.ayu.shortlink.project.common.constant;

/**
 * RocketMQ的常量
 */
public class RocketMQConstant {

    /**
     * 数据聚合主题
     */
    public final static String UNION_DATA_TOPIC = "short-link_rocketmq-topic_union-data";

    /**
     * 数据聚合消费者组
     */
    public final static String UNION_DATA_CONSUMER = "short-link_rocketmq-consumer_union-data";

    /**
     * 通知Caffeine缓存HotKey的主题
     */
    public final static String CACHE_HOTKEY_TOPIC = "short-link_rocketmq-topic_cache-hot-key";

    /**
     * 通知Caffeine缓存HotKey的消费者组
     */
    public final static String CACHE_HOTKEY_CONSUMER = "short-link_rocketmq-consumer_cache-hot-key";
}
